package io.xxx.xbutler.core.select.receiver;

import io.xxx.xbutler.domain.SelectMode;
import io.xxx.xbutler.domain.task.Receiver;
import io.xxx.xbutler.domain.task.Task;
import reactor.core.publisher.Flux;

public interface ReceiverSelector {

    /**
     * 选择接收消息的对象。
     */
    Flux<Receiver> select(Task task);

    boolean supports(SelectMode selectMode);
}
